package job.sql.random;

import java.io.IOException;
import java.util.Iterator;

import mapred.base.TextReducer;

import org.apache.hadoop.io.Text;

public class Sql_Random_Reducer extends TextReducer {

    @Override
    public void reduce(Text key, Iterator<Text> values) throws IOException {
        String k = key.toString();
        k = k.substring(k.indexOf(" ") + 1);
        while (values.hasNext()) {
            this.output(new Text(k), values.next());
        }
    }

    @Override
    public void setUp() {
    }

    @Override
    public void tearDown() throws IOException {
    }

}
